
insert overwrite table jms_dwd.dwd_yl_oms_interceptorrecord_base_dt partition(dt)
select
    waybill_no
    ,interceptor_piece_id
    ,intercept_network_id
    ,intercept_network_name
    ,intercept_network_code
    ,intercept_id
    ,intercept_name
    ,intercept_code
    ,intercept_time
    ,scan_time
    ,operation_source
    ,dt
from jms_ods.yl_oms_interceptorrecord_di
where dt = '{{ execution_date | cst_ds }}'
distribute by dt;